package cn.controlsys.common.mq;

/**
 * Description: mq常量类
 * @author: shanzheng
 * @date: 15:42 2018/1/26
 * @return:
 */
public class MQConstants {
    //线程数
    public final static int THREAD_COUNT = 5;

    //处理间隔时间
    //mils
    public final static int INTERVAL_MILS = 0;

    //consumer失败后等待时间(mils)
    public static final int ONE_SECOND = 1 * 1000;

    //异常sleep时间(mils)
    public static final int ONE_MINUTE = 1 * 60 * 1000;
    //MQ消息retry时间
    public static final int RETRY_TIME_INTERVAL = ONE_MINUTE;
    //MQ消息有效时间
    public static final int VALID_TIME = ONE_MINUTE;

    /**
     * Field EXCHANGE_DIRECT_TYPE : RabbitMQ交换器的使用类型 -- direct
     */
    public static final String EXCHANGE_DIRECT_TYPE = "direct";
    /**
     * Field EXCHANGE_TOPIC_TYPE : RabbitMQ交换器的使用类型 -- topic
     */
    public static final String EXCHANGE_TOPIC_TYPE = "topic";

    public static final String TOPIC_EXCHANGE = "operation.exchange";

    public static final String SAIHEYI_OPERATION_QUEUE = "saiheyi.operation.queue";

    public static final String SAIHEYI_OPERATION_KEY = "saiheyi.operation.routingKey";


}
